//package com.per.mybootall.rabbitmq.finllyAgreement;
//
//import com.per.mybootall.dao.UserMapper;
//import com.per.mybootall.pojo.User;
//import org.springframework.stereotype.Component;
//import org.springframework.transaction.annotation.Transactional;
//
//import javax.annotation.Resource;
//
///**
// * mq最终一致性
// *
// * */
//@Component
//public class MqFinllyAgreement {
//
//    @Resource
//    private UserMapper userMapper;
//    /**
//    * 业务操作
//     * */
//    @Transactional
//    public void someDoing() throws Exception {
//        System.out.println("准备进行业务操作===》》");
//        //在进入业务操作之前需要先向db中写入数据，状态为待发送
//        int res=userMapper.insert(new User());
//        System.out.println("开始进行业务操作===========》》》》》");
//        System.out.println("=====》》》");
//        System.out.println("业务操作执行完毕.........");
//        int resU=userMapper.updateByPrimaryKey(new User());
//        if(resU>0){
//            System.out.println("db消息状态变更成功");
//        }else{
//                throw new Exception("db消息变更失败");
//        }
//}
//}
